package com.fly.easy.queue.common;

import org.apache.log4j.Logger;

import com.alibaba.fastjson.JSON;
import com.fly.easy.queue.croe.FlyMessageHandle;
import com.fly.easy.queue.utils.ThreadUtil;

public class SimpleMssageHandle implements FlyMessageHandle {
	private Logger logger = Logger.getLogger(SimpleMssageHandle.class);

	public void proccess(MessageEntity entity) {
		/**
		 * 模拟耗时10秒
		 */
        //ThreadUtil.sleep(50);		
		logger.info("Thread"+Thread.currentThread().getName()+"-"+JSON.toJSONString(entity));
	}
}
